package com.t2t.top.framework.rocketmq.client.extension;

import java.io.Serializable;

/**
 * 消费者类实现该接口，进行具体业务操作
 */
public interface MessageConsumer<E extends Serializable> {

    public void consume(E messageObject) throws Exception;

}